package com.imooc.article.stream;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.SubscribableChannel;
import org.springframework.stereotype.Component;

/**
 * @Project_name: imooc-news-dev
 * @Description:
 * @Author: Levi
 * @Date: 2021/4/2 16:19
 */
@Component
public interface MyStreamChannel {

    String INPUT = "myInput";
    String OUTPUT = "myOutput";



    @Input(MyStreamChannel.INPUT)
    SubscribableChannel input();

    @Output(MyStreamChannel.OUTPUT)
    MessageChannel output();
}
